package com.lzq.mq.common.dto;

import io.netty.channel.ChannelHandlerContext;
import lombok.AllArgsConstructor;
import lombok.Data;

import java.util.concurrent.atomic.AtomicInteger;

@Data
@AllArgsConstructor
public class SlaveAckDTO {

    /**
     * 需要接收多少个从节点的ack信号
     */
    private AtomicInteger needAckTime;

    /**
     * 需要同步的broker连接主节点的channel
     */
    private ChannelHandlerContext brokerChannel;

}
